package com.jacquesh.partition;

import org.apache.flink.api.common.functions.Partitioner;

public class CustomPartitioner  implements  Partitioner<Long> {
    @Override
    public int partition(Long val, int i) {
        return val.hashCode() % i;
    }
}
